from elasticsearch import Elasticsearch


es = Elasticsearch("121.36.78.226")
body = {




  "query": {
    "bool": {
      "must": [
        {
          "range": {
            "@timestamp": {
              "format": "strict_date_optional_time",
              "gte": "2020-05-12T09:06:50.113Z",
              "lte": "2020-05-19T09:06:50.114Z"
            }
          }
        }
      ],
      "filter": [
        {
          "match_all": {}
        }
      ],
      "should": [],
      "must_not": []
    }
  }
}




res = es.search(index="flow-*", filter_path=["hits.hits._source.message"], body=body)


print(res)